package portal.mq;


import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.amqp.core.Message;
import org.springframework.amqp.core.MessageListener;


public class MQReceiver implements MessageListener {

    private Logger logger= LoggerFactory.getLogger(MQReceiver.class);
    @Override
    public void onMessage(Message message) {
        try{
            //String messageInfo= new String(message.getBody(),"utf-8");
            ///System.out.println(messageInfo);

            //unSerializeObject(message.getBody(),null);
            //logger.info(messageInfo);
        /*}catch (UnsupportedEncodingException e){
            logger.error("UnsupportedEncodingException !!!!!!!");
            e.printStackTrace();*/
        }catch(Exception e){
            e.printStackTrace();
        }
    }
}
